package com.iot.app.flink.vo;

public class KafkaProp {


    private int parallel;
    private String topic;
    private String groupId;
    private String commitment;
    private String reset;
    private String bootstrapServers;

    public KafkaProp() {

    }

    public KafkaProp(int parallel, String topic, String groupId,
                     String commitment, String reset, String bootstrapServers) {
        super();
        this.parallel = parallel;
        this.topic = topic;
        this.groupId = groupId;
        this.commitment = commitment;
        this.reset = reset;
        this.bootstrapServers = bootstrapServers;
    }

    public int getParallel() {
        return parallel;
    }

    public String getTopic() {
        return topic;
    }

    public String getGroupId() {
        return groupId;
    }

    public String getCommitment() {
        return commitment;
    }

    public String getReset() {
        return reset;
    }

    public String getBootstrapServers() {
        return bootstrapServers;
    }


}
